package com.lyj.cloud.business;

import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;

@Component
public class ProductMessage {

	@StreamListener(com.lyj.cloud.pipe.ProductProcessor.INPUT_PRODUCT_ADD)
    public void inputProductAdd(Message<String> message) {
		System.out.println("=====产品监听收到=====");
        System.out.println("新增产品监听收到：" + message.getPayload());
        System.out.println("=====产品处理完成=====");
    }
}
